#include "../../client/rpc_client.hpp"
#include <thread>





int main()
{
    auto client = std::make_shared<Json_rpc::client::TopicClient>("127.0.0.1",8080);

    bool ret =client->create("news");
    if(ret==false)
    {
        ELOG("创建失败");
        return 0;
    }


    for(int i=0 ;i <10 ;i++)
    {
        client->publish("news","！！！！！！！！！！！"+std::to_string(i));
    }

    client->shutdown();
    return 0;
}